<?php

include_once '../dao/BDConexao.php';
include_once '../model/Mensagem.php';
include_once '../model/Conta.php';

/*
 */

/**
 *
 * @author douglas
 */
class BDMensagem {

    private $conexao;

    public function __construct() {
        $this->conexao = Conexao::singleton();
    }

    public function salvar(Mensagem $mensagem) {
        $this->conexao->insert("INSERT INTO TBL_MENSAGEM " .
                "(DS_MENSAGEM, CD_CONTA_ORIGEM, CD_CONTA_DESTINO) " .
                "VALUES('" . $mensagem->getMensagem() . "'," .
                $mensagem->getContaOrigem()->getCodigo() . "," .
                $mensagem->getContaDestino()->getCodigo() . ");");
    }

    public function buscar($conta) {
        $result = $this->conexao->getConexao()->query("SELECT * FROM TBL_MENSAGEM ". 
                "INNER JOIN TBL_CONTA ON TBL_CONTA.CD_CONTA = TBL_MENSAGEM.CD_CONTA_ORIGEM ".
                "WHERE CD_CONTA_DESTINO = " . $conta);
        $mensagens;
        $codigo;
        while ($row = mysqli_fetch_array($result)) {
            $contaOrigem = new Conta();
            $contaOrigem->setCodigo($row['CD_CONTA']);
            $contaOrigem->setNome($row['DS_NOME']);
            $contaDestino = new Conta();
            $contaDestino->setCodigo($conta);
            $codigo = $row['CD_MENSAGEM'];
            $mensagens[$codigo] = new Mensagem($row['DS_MENSAGEM'], $contaOrigem, $contaDestino);
            $mensagens[$codigo]->setCodigo($row['CD_MENSAGEM']);
        }
        return $mensagens;
    }
}

?>
